home *** CD-ROM | disk | FTP | other *** search
/ Celestin Apprentice 5 / Apprentice-Release5.iso / Source Code / C / Applications / Python 1.3.3 / Python 133 SRC / Python / thread_pthread.h < prev    next >
Text File  |  1995-12-21  |  7KB  |  284 lines
  1. /***********************************************************
  2. Copyright 1991-1995 by Stichting Mathematisch Centrum, Amsterdam,
  3. The Netherlands.
  4.  
  5.                         All Rights Reserved
  6.  
  7. Permission to use, copy, modify, and distribute this software and its 
  8. documentation for any purpose and without fee is hereby granted, 
  9. provided that the above copyright notice appear in all copies and that
  10. both that copyright notice and this permission notice appear in 
  11. supporting documentation, and that the names of Stichting Mathematisch
  12. Centrum or CWI not be used in advertising or publicity pertaining to
  13. distribution of the software without specific, written prior permission.
  14.  
  15. STICHTING MATHEMATISCH CENTRUM DISCLAIMS ALL WARRANTIES WITH REGARD TO
  16. THIS SOFTWARE, INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY AND
  17. FITNESS, IN NO EVENT SHALL STICHTING MATHEMATISCH CENTRUM BE LIABLE
  18. FOR ANY SPECIAL, INDIRECT OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
  19. WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
  20. ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT
  21. OF OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
  22.  
  23. ******************************************************************/
  24.  
  25. #ifdef sun
  26. #define FLORIDA_HACKS
  27. #endif
  28.  
  29. #ifdef FLORIDA_HACKS
  30. /* Hacks for Florida State Posix threads implementation */
  31. #undef _POSIX_THREADS
  32. #include "/ufs/guido/src/python/Contrib/pthreads/src/pthread.h"
  33. #define pthread_attr_default ((pthread_attr_t *)0)
  34. #define pthread_mutexattr_default ((pthread_mutexattr_t *)0)
  35. #define pthread_condattr_default ((pthread_condattr_t *)0)
  36. #define TRYLOCK_OFFSET 1
  37. #else /* !FLORIDA_HACKS */
  38. #include <pthread.h>
  39. #define TRYLOCK_OFFSET 0
  40. #endif /* FLORIDA_HACKS */
  41. #include <stdlib.h>
  42.  
  43. /* A pthread mutex isn't sufficient to model the Python lock type
  44.  * because, according to Draft 5 of the docs (P1003.4a/D5), both of the
  45.  * following are undefined:
  46.  *  -> a thread tries to lock a mutex it already has locked
  47.  *  -> a thread tries to unlock a mutex locked by a different thread
  48.  * pthread mutexes are designed for serializing threads over short pieces
  49.  * of code anyway, so wouldn't be an appropriate implementation of
  50.  * Python's locks regardless.
  51.  *
  52.  * The pthread_lock struct implements a Python lock as a "locked?" bit
  53.  * and a <condition, mutex> pair.  In general, if the bit can be acquired
  54.  * instantly, it is, else the pair is used to block the thread until the
  55.  * bit is cleared.     9 May 1994 tim@ksr.com
  56.  */
  57.  
  58. typedef struct {
  59.     char             locked; /* 0=unlocked, 1=locked */
  60.     /* a <cond, mutex> pair to handle an acquire of a locked lock */
  61.     pthread_cond_t   lock_released;
  62.     pthread_mutex_t  mut;
  63. } pthread_lock;
  64.  
  65. #define CHECK_STATUS(name)  if (status < 0) { perror(name); error=1; }
  66.  
  67. /*
  68.  * Initialization.
  69.  */
  70. static void _init_thread _P0()
  71. {
  72. }
  73.  
  74. /*
  75.  * Thread support.
  76.  */
  77.  
  78.  
  79. int start_new_thread _P2(func, void (*func) _P((void *)), arg, void *arg)
  80. {
  81. #if defined(SGI_THREADS) && defined(USE_DL)
  82.     long addr, size;
  83.     static int local_initialized = 0;
  84. #endif /* SGI_THREADS and USE_DL */
  85.     pthread_t th;
  86.     int success;
  87.     dprintf(("start_new_thread called\n"));
  88.     if (!initialized)
  89.         init_thread();
  90.     success = pthread_create(&th, pthread_attr_default, func, arg);
  91.     return success < 0 ? 0 : 1;
  92. }
  93.  
  94. long get_thread_ident _P0()
  95. {
  96.     pthread_t threadid;
  97.     if (!initialized)
  98.         init_thread();
  99.     /* Jump through some hoops for Alpha OSF/1 */
  100.     threadid = pthread_self();
  101.     return (long) *(long *) &threadid;
  102. }
  103.  
  104. static void do_exit_thread _P1(no_cleanup, int no_cleanup)
  105. {
  106.     dprintf(("exit_thread called\n"));
  107.     if (!initialized)
  108.         if (no_cleanup)
  109.             _exit(0);
  110.         else
  111.             exit(0);
  112. }
  113.  
  114. void exit_thread _P0()
  115. {
  116.     do_exit_thread(0);
  117. }
  118.  
  119. void _exit_thread _P0()
  120. {
  121.     do_exit_thread(1);
  122. }
  123.  
  124. #ifndef NO_EXIT_PROG
  125. static void do_exit_prog _P2(status, int status, no_cleanup, int no_cleanup)
  126. {
  127.     dprintf(("exit_prog(%d) called\n", status));
  128.     if (!initialized)
  129.         if (no_cleanup)
  130.             _exit(status);
  131.         else
  132.             exit(status);
  133. }
  134.  
  135. void exit_prog _P1(status, int status)
  136. {
  137.     do_exit_prog(status, 0);
  138. }
  139.  
  140. void _exit_prog _P1(status, int status)
  141. {
  142.     do_exit_prog(status, 1);
  143. }
  144. #endif /* NO_EXIT_PROG */
  145.  
  146. /*
  147.  * Lock support.
  148.  */
  149. type_lock allocate_lock _P0()
  150. {
  151.     pthread_lock *lock;
  152.     int status, error = 0;
  153.  
  154.     dprintf(("allocate_lock called\n"));
  155.     if (!initialized)
  156.         init_thread();
  157.  
  158.     lock = (pthread_lock *) malloc(sizeof(pthread_lock));
  159.     if (lock) {
  160.         lock->locked = 0;
  161.  
  162.         status = pthread_mutex_init(&lock->mut,
  163.                         pthread_mutexattr_default);
  164.         CHECK_STATUS("pthread_mutex_init");
  165.  
  166.         status = pthread_cond_init(&lock->lock_released,
  167.                        pthread_condattr_default);
  168.         CHECK_STATUS("pthread_cond_init");
  169.  
  170.         if (error) {
  171.             free((void *)lock);
  172.             lock = 0;
  173.         }
  174.     }
  175.  
  176.     dprintf(("allocate_lock() -> %lx\n", (long)lock));
  177.     return (type_lock) lock;
  178. }
  179.  
  180. void free_lock _P1(lock, type_lock lock)
  181. {
  182.     pthread_lock *thelock = (pthread_lock *)lock;
  183.     int status, error = 0;
  184.  
  185.     dprintf(("free_lock(%lx) called\n", (long)lock));
  186.  
  187.     status = pthread_mutex_destroy( &thelock->mut );
  188.     CHECK_STATUS("pthread_mutex_destroy");
  189.  
  190.     status = pthread_cond_destroy( &thelock->lock_released );
  191.     CHECK_STATUS("pthread_cond_destroy");
  192.  
  193.     free((void *)thelock);
  194. }
  195.  
  196. int acquire_lock _P2(lock, type_lock lock, waitflag, int waitflag)
  197. {
  198.     int success;
  199.     pthread_lock *thelock = (pthread_lock *)lock;
  200.     int status, error = 0;
  201.  
  202.     dprintf(("acquire_lock(%lx, %d) called\n", (long)lock, waitflag));
  203.  
  204.     status = pthread_mutex_lock( &thelock->mut );
  205.     CHECK_STATUS("pthread_mutex_lock[1]");
  206.     success = thelock->locked == 0;
  207.     if (success) thelock->locked = 1;
  208.     status = pthread_mutex_unlock( &thelock->mut );
  209.     CHECK_STATUS("pthread_mutex_unlock[1]");
  210.  
  211.     if ( !success && waitflag ) {
  212.         /* continue trying until we get the lock */
  213.  
  214.         /* mut must be locked by me -- part of the condition
  215.          * protocol */
  216.         status = pthread_mutex_lock( &thelock->mut );
  217.         CHECK_STATUS("pthread_mutex_lock[2]");
  218.         while ( thelock->locked ) {
  219.             status = pthread_cond_wait(&thelock->lock_released,
  220.                            &thelock->mut);
  221.             CHECK_STATUS("pthread_cond_wait");
  222.         }
  223.         thelock->locked = 1;
  224.         status = pthread_mutex_unlock( &thelock->mut );
  225.         CHECK_STATUS("pthread_mutex_unlock[2]");
  226.         success = 1;
  227.     }
  228.     if (error) success = 0;
  229.     dprintf(("acquire_lock(%lx, %d) -> %d\n", (long)lock, waitflag, success));
  230.     return success;
  231. }
  232.  
  233. void release_lock _P1(lock, type_lock lock)
  234. {
  235.     pthread_lock *thelock = (pthread_lock *)lock;
  236.     int status, error = 0;
  237.  
  238.     dprintf(("release_lock(%lx) called\n", (long)lock));
  239.  
  240.     status = pthread_mutex_lock( &thelock->mut );
  241.     CHECK_STATUS("pthread_mutex_lock[3]");
  242.  
  243.     thelock->locked = 0;
  244.  
  245.     status = pthread_mutex_unlock( &thelock->mut );
  246.     CHECK_STATUS("pthread_mutex_unlock[3]");
  247.  
  248.     /* wake up someone (anyone, if any) waiting on the lock */
  249.     status = pthread_cond_signal( &thelock->lock_released );
  250.     CHECK_STATUS("pthread_cond_signal");
  251. }
  252.  
  253. /*
  254.  * Semaphore support.
  255.  */
  256. /* NOTE: 100% non-functional at this time - tim */
  257.  
  258. type_sema allocate_sema _P1(value, int value)
  259. {
  260.     char *sema = 0;
  261.     dprintf(("allocate_sema called\n"));
  262.     if (!initialized)
  263.         init_thread();
  264.  
  265.     dprintf(("allocate_sema() -> %lx\n", (long) sema));
  266.     return (type_sema) sema;
  267. }
  268.  
  269. void free_sema _P1(sema, type_sema sema)
  270. {
  271.     dprintf(("free_sema(%lx) called\n", (long) sema));
  272. }
  273.  
  274. void down_sema _P1(sema, type_sema sema)
  275. {
  276.     dprintf(("down_sema(%lx) called\n", (long) sema));
  277.     dprintf(("down_sema(%lx) return\n", (long) sema));
  278. }
  279.  
  280. void up_sema _P1(sema, type_sema sema)
  281. {
  282.     dprintf(("up_sema(%lx)\n", (long) sema));
  283. }
  284.